Knx interfacer #200
Knx interfacer #200
Conversation
|
Thanks, Is it possible to add a readme with some documentation and link it into the docs here: https://github.com/openenergymonitor/emonhub/blob/master/docs/emonhub-interfacers.md#list-of-interfacers---links-to-github |
|
Hello, Yes, sure. Laurent |
|
Hello guys, This pull request is open for more then one year ! Thanks, |
| self.loop = asyncio.get_event_loop() | ||
|
|
||
| task = self.loop.create_task(self.initKnx(gateway_ip, local_ip)) | ||
| self.loop.run_until_complete(task) |
There was a problem hiding this comment.
Just a throught, is it threadsafe to use run_until_complete like that ?
| self.ser = False | ||
|
|
||
|
|
||
| def action(self): |
There was a problem hiding this comment.
Not sure this is really needed.
| self.buffer.storeItem(f) | ||
|
|
||
|
|
||
| async def waitSensor(self): |
There was a problem hiding this comment.
Is this used somewhere ?
| def set(self, **kwargs): | ||
| for key, setting in self._KNX_settings.items(): | ||
| # Decide which setting value to use | ||
| if key in kwargs: |
There was a problem hiding this comment.
You could do setting = kwargs.get(key, self._KNX_settings[key]) and remove the whole if else
| metters = self._settings['meters'] | ||
|
|
||
| self.sensor={} | ||
| for metter in metters: |
There was a problem hiding this comment.
possible to use items() like you do below ?
| for metter in metters: | ||
| dpPoint = metters[metter] | ||
|
|
||
| for dpKey in dpPoint: |
There was a problem hiding this comment.
same I think you can iterate with items()
use var name like dp_config (snake case) and not dpConfig (camel case). the OEM maintainers are not using pylint to analyse their code but I think they should :-) I think the xknx lib is following this pattern and I think emonhub began like that, see the emonhub_interfacer base code
| import threading | ||
|
|
||
| from emonhub_interfacer import EmonHubInterfacer | ||
| from xknx import XKNX |
There was a problem hiding this comment.
xknx should be integrated in the dependencies....or maybe just a mention in the interfacer README
|
|
||
|
|
||
| class Updater(threading.Thread): | ||
| def __init__(self, knxIntf): |
There was a problem hiding this comment.
you dont give any var when you initialize the updater in self.start. What is knxIntf ?
Add a new interfacer to connect to a KNX bus to collect datagram from KNX group.